package cn.ipanel.bigdata.dw.dim.mysql

import cn.ipanel.bigdata.boot.source.genre.Mysql
import cn.ipanel.bigdata.dw.dws.HBASE_NAMESPACE
import org.apache.spark.sql.Dataset

/**
 * @author lzz
 * @environment IntelliJ IDEA 2020.3.1
 * @projectName bigdata_panyu   番禺大数据，区域数据
 * @date 2023/11/14 16:15
 * @description:
 */
protected[mysql] object ExtraDevice extends Mysql("iot_db", "t_device_info") {

  final val F_DEVICE_ID       : String = "f_device_id"      // IOT设备id
  final val F_ADDRESS_ID      : String = "f_address_id"     // 设备所在地址id
  final val F_ROOM_ID         : String = "f_room_id"        // 设备所在房间id
  final val F_USER_ID         : String = "f_user_id"        // 创建设备的用户ID
  final val F_DEVICE_TYPE     : String = "f_device_type"    // 设备类型
  final val F_DEVICE_MAC      : String = "f_device_mac"     // 设备mac地址
  final val F_DEVICE_NAME     : String = "f_device_name"    // 设备名称
  final val F_REGION_CODE     : String = "f_region_code"    // 设备所在区域编码
  final val F_EXTEND          : String = "f_extend"         // 设备扩展信息
  final val F_CREATE_TIME     : String = "f_create_time"    // 创建时间

  override def getTBColumns: Seq[String] = {
    Seq(F_DEVICE_ID, F_ADDRESS_ID, F_ROOM_ID, F_USER_ID, F_DEVICE_TYPE,
      F_DEVICE_MAC, F_DEVICE_NAME, F_REGION_CODE, F_EXTEND, F_CREATE_TIME)
  }

  override def buildTable: String = ???

  override def emptyTable: Dataset[_] = ???

}